package cn.tannn.tcache.resp;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import lombok.extern.slf4j.Slf4j;

/**
 * 协议
 *
 * @author <a href="https://t.tannn.cn/">tnnn</a>
 * @version V1.0
 * @date 2024/6/15 下午11:21
 */
@Slf4j
public class Protocol {

    /**
     * 封装数据 - content是已经组装好的 redis协议格式内容
     *
     * @param ctx     ChannelHandlerContext
     * @param content redis协议格式的数据内容
     */
    public static void writeByteBuf(ChannelHandlerContext ctx, String content) {
        log.debug("wrap byte buffer and reply: {}", content);
        ByteBuf buffer = Unpooled.buffer(128);
        buffer.writeBytes(content.getBytes());
        ctx.writeAndFlush(buffer);
    }
}
